
// 连接Mysql
var express = require('express')
var mysql = require('mysql');
var router = express.Router();
// // 数据库连接配置
var pool = mysql.createPool({
    host: '39.108.55.194',    // 数据库的地址
    // host: 'localhost',    // 数据库的地址
    port: '3306',            //数据库端口
    user: 'root',         // 数据库用户名
    password: 'sb145236789',     // 数据库密码
    database: 'employdb'   // 数据库名称   
})
// // 对数据库进行增删改查操作的基础
module.exports = (sql, callback) => {
    pool.getConnection((err, connection) => {

        if (err) {
            console.log("连接MySQL失败，错误信息：" + err);
        } else {

            // connectInfo(connection);
            // console.log("连接数：" + pool._allConnections.length);
            connection.query(sql, (err, rows) => {
                callback(err, rows)
                connection.release()
                // console.log("连接数：" + pool._allConnections.length);

            })
        }

    })
}


// connectInfo = (connection) => {
//     let { host, port, user, password, database } = connection.config;
//     let { state } = connection;
//     console.log(`MySql : ${host} : ${port} DB:${database} ${state}`);
// }